package com.atguigu.redis_springboot.base;


import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;

import java.util.HashSet;
import java.util.Set;

/**
 * redis集群操作
 */
public class JedisClusterTest {
    public static void main(String[] args) {
        // 创建连接对象

        // 连接一个服务
//        HostAndPort hostAndPort = new HostAndPort("192.168.200.11", 6379);
//        JedisCluster jedisCluster = new JedisCluster(hostAndPort);

        // 连接多个服务，因为集群的互通性，与连接一个服务等价
        Set<HostAndPort> set = new HashSet<HostAndPort>();
        set.add(new HostAndPort("192.168.200.11", 6379));
        set.add(new HostAndPort("192.168.200.11", 6380));
        JedisCluster jedisCluster = new JedisCluster(set);

        jedisCluster.set("k1", "v1");
        System.out.println(jedisCluster.get("k1"));
        jedisCluster.close();
    }
}
